package com.aiwiown.snackmq.api.config;

import lombok.Builder;
import lombok.Getter;

@Getter
@Builder
public class ProducerConfig {
    /** 批次大小，一个批次最多包含的消息数量 */
    @Builder.Default
    private int batchSize = 1000;

    /** 逗留时间（毫秒），即使批次未满，消息在缓冲区停留的最长时间 */
    @Builder.Default
    private long lingerMs = 10;

    /** 生产者缓冲区总大小（字节） */
    @Builder.Default
    private long bufferMemory = 32 * 1024 * 1024; // 32MB


    /** 【新增】用户名，用于认证 */
    private String username;

    /** 【新增】密码，用于认证 */
    private String password;
}